package kafkastudy.concurrent.consumerthread;


import kafkastudy.concurrent.ProducerThread;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.Properties;

/**
 * Author  : RandySun (sunfeng152157@sina.com)
 * Date    : 2017-08-20  14:18
 * Comment :
 */
public class ConsumerGroupMain {

    public static void main(String[] args){
        String brokers = "10.1.1.42:9092,10.1.1.43:9092,10.1.1.44:9092";
        String groupId = "dev_group15";
        String topic = "logrule";
        int consumerNumber = 3;

        Thread producerThread = new Thread(new ProducerThread(brokers,topic));
        producerThread.start();

//        ConsumerGroup consumerGroup = new ConsumerGroup(brokers,groupId,topic,consumerNumber);
//        consumerGroup.start();
    }
}
